package ar.uba.is2.ec.scmanager;

import java.util.Collection;
import java.util.HashSet;

import ar.uba.is2.common.mensaje.Mensaje;
import ar.uba.is2.common.mensaje.Receptor;
import ar.uba.is2.common.mensaje.contenido.ContenidoSuscripcionDato;
import ar.uba.is2.common.mensaje.contenido.Identificador;

public class ReceptorSuscripcionDeDatos implements Receptor {

	public static final Collection<Identificador> identificadoresSuscriptos = new HashSet<Identificador>();

	@Override
	public void recibirMensaje(Mensaje mensaje) {

		ContenidoSuscripcionDato contenido = (ContenidoSuscripcionDato) mensaje.getContenido();
		
		Identificador id = contenido.getContenido();
		
		if (!identificadoresSuscriptos.contains(id)) {
			identificadoresSuscriptos.add(id);
		}
	}

}
